721464ea4c59a21d8e1069bfdb1aae294438141b,src/main/java/io/nats/stan/SubscriptionImpl.java,SubscriptionImpl,unsubscribe,#,73
Before Change
if (reply.getData() == null) {
response = SubscriptionResponse.parseFrom(new byte[0]);
} else {
response = SubscriptionResponse.parseFrom(reply.getData());
}
logger.trace("Received Unsubscribe SubscriptionResponse:\n{}", response);
if (!response.getError().isEmpty()) {
After Change
} catch (TimeoutException e) {
throw new TimeoutException(ConnectionImpl.ERR_TIMEOUT);
}
SubscriptionResponse response = SubscriptionResponse.parseFrom(reply.getData());
logger.trace("Received Unsubscribe SubscriptionResponse:\n{}", response);
if (!response.getError().isEmpty()) {
throw new IOException("stan: " + response.getError());